8160bf0535049e1e44baee889d981e5c9a1ddccb,rxbinding/src/main/java/com/jakewharton/rxbinding/widget/RadioGroupCheckedChangeEventOnSubscribe.java,RadioGroupCheckedChangeEventOnSubscribe,call,#Subscriber#,20
Before Change
}
};
Subscription subscription = Subscriptions.create(new Action0() {
@Override public void call() {
view.setOnCheckedChangeListener(null);
}
});
subscriber.add(subscription);
view.setOnCheckedChangeListener(listener);
After Change
this.view = view;
}
@Override public void call(final Subscriber<? super RadioGroupCheckedChangeEvent> subscriber) {
checkUiThread();
RadioGroup.OnCheckedChangeListener listener = new RadioGroup.OnCheckedChangeListener() {
@Override public void onCheckedChanged(RadioGroup group, int checkedId) {
if (!subscriber.isUnsubscribed()) {
subscriber.onNext(RadioGroupCheckedChangeEvent.create(group, checkedId));
}
}
};
subscriber.add(new MainThreadSubscription() {
@Override protected void onUnsubscribe() {
view.setOnCheckedChangeListener(null);
}
});
view.setOnCheckedChangeListener(listener);